🎖️GitЯра🎖️
Node / meshtastic / Meshtastic-Android / files / feature / discovery / src / commonMain / kotlin / org / meshtastic / feature / discovery / DiscoveryTerminalCoordinator.kt
Displaying Raw • Download
feature/discovery/src/commonMain/kotlin/org/meshtastic/feature/discovery/DiscoveryTerminalCoordinator.kt fix/fdroid-map-rendering (113121c4) Text, 14.58 KB
T8b949e/*
* Copyright (c) 2026 Meshtastic LLC
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
Tff7b72package T7ee787org.meshtastic.feature.discovery
Tff7b72import T7ee787co.touchlab.kermit.Logger
Tff7b72import T7ee787kotlinx.coroutines.CoroutineStart
Tff7b72import T7ee787kotlinx.coroutines.Deferred
Tff7b72import T7ee787kotlinx.coroutines.NonCancellable
Tff7b72import T7ee787kotlinx.coroutines.async
Tff7b72import T7ee787kotlinx.coroutines.sync.Mutex
Tff7b72import T7ee787kotlinx.coroutines.sync.withLock
Tff7b72import T7ee787kotlinx.coroutines.withContext
Tff7b72import T7ee787org.meshtastic.core.common.di.ApplicationCoroutineScope
Tff7b72import T7ee787org.meshtastic.core.common.util.safeCatching
Tff7b72import T7ee787org.meshtastic.core.database.dao.DiscoveryDao
Tff7b72import T7ee787org.meshtastic.core.database.entity.DiscoverySessionEntity
Tff7b72import T7ee787org.meshtastic.core.database.entity.DiscoverySessionStatus
Tff7b72internal Tff7b72data Tff7b72class T56d364DiscoveryTerminalRequestTb4b4b4(
Tff7b72val Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4,
Tff7b72val Te6edf3restorePlanTb4b4b4: Te6edf3DiscoveryHomeRestorePlan?Tb4b4b4,
Tff7b72val Te6edf3pendingStatusTb4b4b4: Tffa657StringTb4b4b4,
Tff7b72val Te6edf3outcomeTb4b4b4: Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4,
Tff7b72val Te6edf3awaitRestoreTb4b4b4: Tffa657BooleanTb4b4b4,
Tff7b72val Te6edf3shouldGenerateAiTb4b4b4: Tffa657BooleanTb4b4b4,
Tb4b4b4)
T8b949e/** Serializes terminal scan cleanup and keeps persistence separate from radio restoration ownership. */
Tf0883e@SuppressTb4b4b4(Ta5d6ff"Ta5d6ffTooManyFunctionsTa5d6ff"Tb4b4b4)
Tff7b72internal Tff7b72class T56d364DiscoveryTerminalCoordinatorTb4b4b4(
Tff7b72private Tff7b72val Te6edf3discoveryDaoTb4b4b4: Te6edf3DiscoveryDaoTb4b4b4,
Tff7b72private Tff7b72val Te6edf3homeRestorerTb4b4b4: Te6edf3DiscoveryHomeRestorerTb4b4b4,
Tff7b72private Tff7b72val Te6edf3applicationScopeTb4b4b4: Te6edf3ApplicationCoroutineScopeTb4b4b4,
Tff7b72private Tff7b72val Te6edf3onSessionUpdatedTb4b4b4: Tb4b4b4(Te6edf3DiscoverySessionEntityTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Tff7b72private Tff7b72val Te6edf3onTerminalCompletedTb4b4b4: Tb4b4b4(Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Tff7b72private Tff7b72val Te6edf3cancelScanTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Tb4b4b4) Tb4b4b4{
Tff7b72private Tff7b72data Tff7b72class T56d364TerminalTaskSelectionTb4b4b4(
Tff7b72val Te6edf3taskTb4b4b4: Te6edf3DeferredTff7b72<Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTff7b72>Tb4b4b4,
Tff7b72val Te6edf3acceptedTb4b4b4: Tffa657BooleanTb4b4b4,
Tff7b72val Te6edf3ownerRequestTb4b4b4: Te6edf3DiscoveryTerminalRequestTb4b4b4,
Tb4b4b4)
Tff7b72private Tff7b72data Tff7b72class T56d364SessionAggregatesTb4b4b4(
Tff7b72val Te6edf3totalUniqueNodesTb4b4b4: Tffa657IntTb4b4b4,
Tff7b72val Te6edf3totalDwellSecondsTb4b4b4: Tffa657LongTb4b4b4,
Tff7b72val Te6edf3totalMessagesTb4b4b4: Tffa657IntTb4b4b4,
Tff7b72val Te6edf3totalSensorPacketsTb4b4b4: Tffa657IntTb4b4b4,
Tff7b72val Te6edf3furthestNodeDistanceTb4b4b4: Tffa657DoubleTb4b4b4,
Tff7b72val Te6edf3avgChannelUtilizationTb4b4b4: Tffa657DoubleTb4b4b4,
Tb4b4b4)
Tff7b72private Tff7b72val Te6edf3mutex Tff7b72= Te6edf3MutexTb4b4b4(Tb4b4b4)
Tff7b72private Tff7b72var Te6edf3terminalCompletionTb4b4b4: Te6edf3DeferredTff7b72<Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTff7b72>Tff7b72? Tff7b72= Tff7b72null
Tff7b72private Tff7b72var Te6edf3terminalRequestTb4b4b4: Te6edf3DiscoveryTerminalRequest? Tff7b72= Tff7b72null
Tff7b72private Tff7b72var Te6edf3terminalRestoreTaskTb4b4b4: Te6edf3DeferredTff7b72<Tffa657BooleanTff7b72>Tff7b72? Tff7b72= Tff7b72null
Tff7b72private Tff7b72var Te6edf3terminalRestoreSessionIdTb4b4b4: Tffa657Long? Tff7b72= Tff7b72null
Tff7b72suspend Tff7b72fun Td2a8ffresetForScanTb4b4b4(Tb4b4b4)Tb4b4b4: Tffa657Boolean Tff7b72= Te6edf3mutexTb4b4b4.Te6edf3withLock Tb4b4b4{
Tff7b72if Tb4b4b4(Te6edf3terminalCompletionTff7b72?.Te6edf3isCompleted Tff7b72=Tff7b72= Tff7b72falseTb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{ Ta5d6ff"Ta5d6ffDiscoveryScanEngine: refusing reset while terminal cleanup is activeTa5d6ff" Tb4b4b4}
Tff7b72false
Tb4b4b4} Tff7b72else Tb4b4b4{
Te6edf3terminalCompletion Tff7b72= Tff7b72null
Te6edf3terminalRequest Tff7b72= Tff7b72null
Te6edf3terminalRestoreTask Tff7b72= Tff7b72null
Te6edf3terminalRestoreSessionId Tff7b72= Tff7b72null
Tff7b72true
Tb4b4b4}
Tb4b4b4}
Tff7b72suspend Tff7b72fun Td2a8ffcompleteTb4b4b4(
Te6edf3requestTb4b4b4: Te6edf3DiscoveryTerminalRequestTb4b4b4,
Te6edf3beforeFinalizeTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657Unit Tff7b72= Tb4b4b4{Tb4b4b4}Tb4b4b4,
Te6edf3generateAiTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657Unit Tff7b72= Tb4b4b4{Tb4b4b4}Tb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcome Tb4b4b4{
Tff7b72val Te6edf3selection Tff7b72= Te6edf3terminalTaskTb4b4b4(Te6edf3requestTb4b4b4, Te6edf3beforeFinalizeTb4b4b4, Te6edf3generateAiTb4b4b4)
Tff7b72val Te6edf3sharedOutcome Tff7b72= Te6edf3selectionTb4b4b4.Te6edf3taskTb4b4b4.Te6edf3awaitTb4b4b4(Tb4b4b4)
T8b949e// Joined callers with the same data-class value share the owner's work; changing request equality changes
T8b949e// this deduplication contract.
Tff7b72if Tb4b4b4(Te6edf3selectionTb4b4b4.Te6edf3accepted Tff7b72|Tff7b72| Te6edf3request Tff7b72=Tff7b72= Te6edf3selectionTb4b4b4.Te6edf3ownerRequestTb4b4b4) Tff7b72return Te6edf3sharedOutcome
Te6edf3LoggerTb4b4b4.Te6edf3w Tb4b4b4{
Ta5d6ff"Ta5d6ffDiscoveryScanEngine: terminal request Tffd700${Te6edf3requestTb4b4b4.Te6edf3pendingStatusTffd700}Ta5d6ff joined an active terminal cleanup; Ta5d6ff" Tff7b72+
Ta5d6ff"Ta5d6ffrunning its required follow-up work after the shared cleanupTa5d6ff"
Tb4b4b4}
Tff7b72val Te6edf3joinedOutcome Tff7b72= Te6edf3runJoinedWorkTb4b4b4(Te6edf3requestTb4b4b4, Te6edf3beforeFinalizeTb4b4b4, Te6edf3generateAiTb4b4b4, Te6edf3sharedOutcomeTb4b4b4)
Te6edf3publishJoinedOutcomeIfCurrentTb4b4b4(Te6edf3selectionTb4b4b4.Te6edf3taskTb4b4b4, Te6edf3sharedOutcomeTb4b4b4, Te6edf3joinedOutcomeTb4b4b4)
Tff7b72return Te6edf3joinedOutcome
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffterminalTaskTb4b4b4(
Te6edf3requestTb4b4b4: Te6edf3DiscoveryTerminalRequestTb4b4b4,
Te6edf3beforeFinalizeTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Te6edf3generateAiTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3TerminalTaskSelection Tb4b4b4{
Tff7b72val Te6edf3selection Tff7b72=
Te6edf3mutexTb4b4b4.Te6edf3withLock Tb4b4b4{
Tff7b72val Te6edf3existing Tff7b72= Te6edf3terminalCompletionTff7b72?.Te6edf3takeIf Tb4b4b4{ Tff7b72!Tffa657itTb4b4b4.Te6edf3isCompleted Tb4b4b4}
Tff7b72if Tb4b4b4(Te6edf3existing Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{
Te6edf3TerminalTaskSelectionTb4b4b4(Te6edf3existingTb4b4b4, Te6edf3accepted Tff7b72= Tff7b72falseTb4b4b4, Te6edf3ownerRequest Tff7b72= Te6edf3checkNotNullTb4b4b4(Te6edf3terminalRequestTb4b4b4)Tb4b4b4)
Tb4b4b4} Tff7b72else Tb4b4b4{
Tff7b72val Te6edf3newTask Tff7b72=
Te6edf3applicationScopeTb4b4b4.Te6edf3asyncTb4b4b4(Te6edf3start Tff7b72= Te6edf3CoroutineStartTb4b4b4.Te6edf3LAZYTb4b4b4) Tb4b4b4{
Tff7b72var Te6edf3publishedOutcome Tff7b72= Te6edf3fallbackOutcomeTb4b4b4(Te6edf3requestTb4b4b4.Te6edf3outcomeTb4b4b4)
Tff7b72try Tb4b4b4{
Te6edf3runTerminalCleanupTb4b4b4(Te6edf3requestTb4b4b4, Te6edf3beforeFinalizeTb4b4b4, Te6edf3generateAiTb4b4b4)Tb4b4b4.Te6edf3also Tb4b4b4{ Te6edf3publishedOutcome Tff7b72= Tffa657it Tb4b4b4}
Tb4b4b4} Tff7b72finally Tb4b4b4{
Te6edf3onTerminalCompletedTb4b4b4(Te6edf3publishedOutcomeTb4b4b4)
Tb4b4b4}
Tb4b4b4}
Te6edf3terminalCompletion Tff7b72= Te6edf3newTask
Te6edf3terminalRequest Tff7b72= Te6edf3request
Te6edf3TerminalTaskSelectionTb4b4b4(Te6edf3newTaskTb4b4b4, Te6edf3accepted Tff7b72= Tff7b72trueTb4b4b4, Te6edf3ownerRequest Tff7b72= Te6edf3requestTb4b4b4)
Tb4b4b4}
Tb4b4b4}
T8b949e// The task can acquire the scan-engine mutex through beforeFinalize; never start it under this mutex.
Tff7b72if Tb4b4b4(Te6edf3selectionTb4b4b4.Te6edf3acceptedTb4b4b4) Te6edf3selectionTb4b4b4.Te6edf3taskTb4b4b4.Te6edf3startTb4b4b4(Tb4b4b4)
Tff7b72return Te6edf3selection
Tb4b4b4}
Tff7b72private Tff7b72fun Td2a8fffallbackOutcomeTb4b4b4(Te6edf3requestedTb4b4b4: Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4)Tb4b4b4: Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcome Tff7b72=
Tff7b72if Tb4b4b4(Te6edf3requested Tff7b72=Tff7b72= Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4.Te6edf3SuccessTb4b4b4) Tb4b4b4{
Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4.Te6edf3Failed
Tb4b4b4} Tff7b72else Tb4b4b4{
Te6edf3requested
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffrunTerminalCleanupTb4b4b4(
Te6edf3requestTb4b4b4: Te6edf3DiscoveryTerminalRequestTb4b4b4,
Te6edf3beforeFinalizeTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Te6edf3generateAiTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcome Tb4b4b4{
Tff7b72val Te6edf3cancellationSucceeded Tff7b72= Te6edf3runBestEffortTb4b4b4(Ta5d6ff"Ta5d6ffscan cancellation failed during terminal cleanupTa5d6ff"Tb4b4b4, Te6edf3cancelScanTb4b4b4)
Tff7b72val Te6edf3persistedStatus Tff7b72=
Tff7b72if Tb4b4b4(Te6edf3requestTb4b4b4.Te6edf3restorePlan Tff7b72=Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{
Te6edf3finalStatusForPendingRestoreTb4b4b4(Te6edf3requestTb4b4b4.Te6edf3pendingStatusTb4b4b4, Te6edf3default Tff7b72= Te6edf3requestTb4b4b4.Te6edf3pendingStatusTb4b4b4)
Tb4b4b4} Tff7b72else Tb4b4b4{
Te6edf3requestTb4b4b4.Te6edf3pendingStatus
Tb4b4b4}
Tff7b72var Te6edf3restoreTaskTb4b4b4: Te6edf3DeferredTff7b72<Tffa657BooleanTff7b72>Tff7b72? Tff7b72= Tff7b72null
Tff7b72val Te6edf3persistenceSucceeded Tff7b72=
Tff7b72try Tb4b4b4{
Tff7b72val Te6edf3beforeFinalizeSucceeded Tff7b72=
Te6edf3runBestEffortTb4b4b4(Ta5d6ff"Ta5d6ffdwell persistence failed during terminal cleanupTa5d6ff"Tb4b4b4, Te6edf3beforeFinalizeTb4b4b4)
Tff7b72val Te6edf3terminalPersistSucceeded Tff7b72= Te6edf3persistTerminalSessionTb4b4b4(Te6edf3requestTb4b4b4.Te6edf3sessionIdTb4b4b4, Te6edf3persistedStatusTb4b4b4)
Te6edf3cancellationSucceeded Tff7b72&Tff7b72& Te6edf3beforeFinalizeSucceeded Tff7b72&Tff7b72& Te6edf3terminalPersistSucceeded
Tb4b4b4} Tff7b72finally Tb4b4b4{
T8b949e// Preserve aggregate-before-final-status ordering, but make restore scheduling cancellation-safe so a
T8b949e// database cancellation cannot strand the radio on its scan configuration. Capture the task once so
T8b949e// foreground waiting cannot accidentally schedule a second restore after a fast completion.
Te6edf3withContextTb4b4b4(Te6edf3NonCancellableTb4b4b4) Tb4b4b4{
Te6edf3restoreTask Tff7b72= Te6edf3requestTb4b4b4.Te6edf3restorePlanTff7b72?.Te6edf3let Tb4b4b4{ Te6edf3homeRestorerTb4b4b4.Te6edf3scheduleTb4b4b4(Tffa657itTb4b4b4) Tb4b4b4}
Te6edf3mutexTb4b4b4.Te6edf3withLock Tb4b4b4{
Te6edf3terminalRestoreTask Tff7b72= Te6edf3restoreTask
Te6edf3terminalRestoreSessionId Tff7b72= Te6edf3requestTb4b4b4.Te6edf3sessionIdTb4b4b4.Te6edf3takeIf Tb4b4b4{ Te6edf3restoreTask Tff7b72!Tff7b72= Tff7b72null Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tb4b4b4}
Tff7b72var Te6edf3outcome Tff7b72= Te6edf3outcomeAfterPersistenceTb4b4b4(Te6edf3requestTb4b4b4.Te6edf3outcomeTb4b4b4, Te6edf3persistenceSucceededTb4b4b4)
Tff7b72if Tb4b4b4(Te6edf3requestTb4b4b4.Te6edf3awaitRestore Tff7b72&Tff7b72& Te6edf3restoreTask Tff7b72!Tff7b72= Tff7b72null Tff7b72&Tff7b72& Tff7b72!Te6edf3awaitForegroundRestoreTb4b4b4(Te6edf3checkNotNullTb4b4b4(Te6edf3restoreTaskTb4b4b4)Tb4b4b4)Tb4b4b4) Tb4b4b4{
Te6edf3outcome Tff7b72= Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4.Te6edf3Failed
Te6edf3homeRestorerTb4b4b4.Te6edf3updateFinalStatusTb4b4b4(Te6edf3requestTb4b4b4.Te6edf3sessionIdTb4b4b4, Te6edf3DiscoverySessionStatusTb4b4b4.Te6edf3FAILEDTb4b4b4)
Te6edf3persistPendingRestoreStatusTb4b4b4(Te6edf3requestTb4b4b4.Te6edf3sessionIdTb4b4b4, Te6edf3DiscoverySessionStatusTb4b4b4.Te6edf3RESTORE_PENDING_FAILEDTb4b4b4)
Tb4b4b4}
Tff7b72if Tb4b4b4(Te6edf3requestTb4b4b4.Te6edf3shouldGenerateAi Tff7b72&Tff7b72& Te6edf3outcome Tff7b72=Tff7b72= Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4.Te6edf3SuccessTb4b4b4) Tb4b4b4{
Te6edf3runBestEffortTb4b4b4(Ta5d6ff"Ta5d6ffAI summary generation failedTa5d6ff"Tb4b4b4, Te6edf3generateAiTb4b4b4)
Tb4b4b4}
Tff7b72return Te6edf3outcome
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffrunJoinedWorkTb4b4b4(
Te6edf3requestTb4b4b4: Te6edf3DiscoveryTerminalRequestTb4b4b4,
Te6edf3beforeFinalizeTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Te6edf3generateAiTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4,
Te6edf3sharedOutcomeTb4b4b4: Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcome Tb4b4b4{
Tff7b72val Te6edf3beforeFinalizeSucceeded Tff7b72= Te6edf3runBestEffortTb4b4b4(Ta5d6ff"Ta5d6ffjoined dwell persistence failedTa5d6ff"Tb4b4b4, Te6edf3beforeFinalizeTb4b4b4)
Tff7b72val Te6edf3aggregateSucceeded Tff7b72= Te6edf3persistSessionAggregatesTb4b4b4(Te6edf3requestTb4b4b4.Te6edf3sessionIdTb4b4b4)
Tff7b72var Te6edf3outcome Tff7b72= Te6edf3outcomeAfterPersistenceTb4b4b4(Te6edf3sharedOutcomeTb4b4b4, Te6edf3beforeFinalizeSucceeded Tff7b72&Tff7b72& Te6edf3aggregateSucceededTb4b4b4)
Tff7b72if Tb4b4b4(Te6edf3requestTb4b4b4.Te6edf3awaitRestoreTb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3restoreTask Tff7b72=
Te6edf3mutexTb4b4b4.Te6edf3withLock Tb4b4b4{ Te6edf3terminalRestoreTaskTb4b4b4.Te6edf3takeIf Tb4b4b4{ Te6edf3terminalRestoreSessionId Tff7b72=Tff7b72= Te6edf3requestTb4b4b4.Te6edf3sessionId Tb4b4b4} Tb4b4b4}
Tff7b72if Tb4b4b4(Te6edf3restoreTask Tff7b72!Tff7b72= Tff7b72null Tff7b72&Tff7b72& Tff7b72!Te6edf3awaitForegroundRestoreTb4b4b4(Te6edf3restoreTaskTb4b4b4)Tb4b4b4) Tb4b4b4{
Te6edf3outcome Tff7b72= Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4.Te6edf3Failed
Te6edf3homeRestorerTb4b4b4.Te6edf3updateFinalStatusTb4b4b4(Te6edf3requestTb4b4b4.Te6edf3sessionIdTb4b4b4, Te6edf3DiscoverySessionStatusTb4b4b4.Te6edf3FAILEDTb4b4b4)
Te6edf3persistPendingRestoreStatusTb4b4b4(Te6edf3requestTb4b4b4.Te6edf3sessionIdTb4b4b4, Te6edf3DiscoverySessionStatusTb4b4b4.Te6edf3RESTORE_PENDING_FAILEDTb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tff7b72if Tb4b4b4(Te6edf3requestTb4b4b4.Te6edf3shouldGenerateAi Tff7b72&Tff7b72& Te6edf3outcome Tff7b72=Tff7b72= Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4.Te6edf3SuccessTb4b4b4) Tb4b4b4{
Te6edf3runBestEffortTb4b4b4(Ta5d6ff"Ta5d6ffAI summary generation failedTa5d6ff"Tb4b4b4, Te6edf3generateAiTb4b4b4)
Tb4b4b4}
Tff7b72return Te6edf3outcome
Tb4b4b4}
T8b949e/** Republishes a corrected joined outcome only while the completed task still owns terminal state. */
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffpublishJoinedOutcomeIfCurrentTb4b4b4(
Te6edf3taskTb4b4b4: Te6edf3DeferredTff7b72<Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTff7b72>Tb4b4b4,
Te6edf3sharedOutcomeTb4b4b4: Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4,
Te6edf3joinedOutcomeTb4b4b4: Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4,
Tb4b4b4) Tb4b4b4{
Tff7b72if Tb4b4b4(Te6edf3joinedOutcome Tff7b72=Tff7b72= Te6edf3sharedOutcomeTb4b4b4) Tff7b72return
Te6edf3mutexTb4b4b4.Te6edf3withLock Tb4b4b4{ Tff7b72if Tb4b4b4(Te6edf3terminalCompletion Tff7b72=Tff7b72=Tff7b72= Te6edf3taskTb4b4b4) Te6edf3onTerminalCompletedTb4b4b4(Te6edf3joinedOutcomeTb4b4b4) Tb4b4b4}
Tb4b4b4}
Tff7b72private Tff7b72fun Td2a8ffoutcomeAfterPersistenceTb4b4b4(
Te6edf3requestedTb4b4b4: Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4,
Te6edf3persistenceSucceededTb4b4b4: Tffa657BooleanTb4b4b4,
Tb4b4b4)Tb4b4b4: Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcome Tff7b72=
Tff7b72if Tb4b4b4(Tff7b72!Te6edf3persistenceSucceeded Tff7b72&Tff7b72& Te6edf3requested Tff7b72=Tff7b72= Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4.Te6edf3SuccessTb4b4b4) Tb4b4b4{
Te6edf3DiscoveryScanStateTb4b4b4.Te6edf3CompletionOutcomeTb4b4b4.Te6edf3Failed
Tb4b4b4} Tff7b72else Tb4b4b4{
Te6edf3requested
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffrunBestEffortTb4b4b4(Te6edf3messageTb4b4b4: Tffa657StringTb4b4b4, Te6edf3blockTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Tffa657UnitTb4b4b4)Tb4b4b4: Tffa657Boolean Tb4b4b4{
Tff7b72val Te6edf3result Tff7b72= Te6edf3safeCatching Tb4b4b4{ Te6edf3blockTb4b4b4(Tb4b4b4) Tb4b4b4}
Tff7b72val Te6edf3failure Tff7b72= Te6edf3resultTb4b4b4.Te6edf3exceptionOrNullTb4b4b4(Tb4b4b4)
Tff7b72if Tb4b4b4(Te6edf3failure Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Te6edf3failureTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffDiscoveryScanEngine: Tffd700$Te6edf3messageTa5d6ff" Tb4b4b4}
Tb4b4b4}
Tff7b72return Te6edf3failure Tff7b72=Tff7b72= Tff7b72null
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffpersistPendingRestoreStatusTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4, Te6edf3statusTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Tffa657Boolean Tb4b4b4{
Tff7b72if Tb4b4b4(Te6edf3sessionId Tff7b72=Tff7b72= T79c0ff0LTb4b4b4) Tff7b72return Tff7b72true
Tff7b72return Te6edf3persistAndPublishTb4b4b4(Ta5d6ff"Ta5d6ffpending restore status persistence failedTa5d6ff"Tb4b4b4) Tb4b4b4{
Te6edf3discoveryDaoTb4b4b4.Te6edf3updateRecoverableSessionCompletionStatusTb4b4b4(Te6edf3sessionIdTb4b4b4, Te6edf3statusTb4b4b4)
Te6edf3discoveryDaoTb4b4b4.Te6edf3getSessionTb4b4b4(Te6edf3sessionIdTb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffpersistTerminalSessionTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4, Te6edf3statusTb4b4b4: Tffa657StringTb4b4b4)Tb4b4b4: Tffa657Boolean Tb4b4b4{
Tff7b72if Tb4b4b4(Te6edf3sessionId Tff7b72=Tff7b72= T79c0ff0LTb4b4b4) Tff7b72return Tff7b72true
Tff7b72return Te6edf3persistAndPublishTb4b4b4(Ta5d6ff"Ta5d6ffterminal session persistence failedTa5d6ff"Tb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3aggregates Tff7b72= Te6edf3calculateSessionAggregatesTb4b4b4(Te6edf3sessionIdTb4b4b4) Tff7b72?: Tff7b72returnTf0883e@persistAndPublish Tff7b72null
Te6edf3updateSessionAggregatesTb4b4b4(Te6edf3sessionIdTb4b4b4, Te6edf3aggregatesTb4b4b4)
Te6edf3discoveryDaoTb4b4b4.Te6edf3updateRecoverableSessionCompletionStatusTb4b4b4(Te6edf3sessionIdTb4b4b4, Te6edf3statusTb4b4b4)
Te6edf3discoveryDaoTb4b4b4.Te6edf3getSessionTb4b4b4(Te6edf3sessionIdTb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffpersistSessionAggregatesTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4)Tb4b4b4: Tffa657Boolean Tb4b4b4{
Tff7b72if Tb4b4b4(Te6edf3sessionId Tff7b72=Tff7b72= T79c0ff0LTb4b4b4) Tff7b72return Tff7b72true
Tff7b72return Te6edf3persistAndPublishTb4b4b4(Ta5d6ff"Ta5d6ffterminal aggregate persistence failedTa5d6ff"Tb4b4b4) Tb4b4b4{
Tff7b72val Te6edf3aggregates Tff7b72= Te6edf3calculateSessionAggregatesTb4b4b4(Te6edf3sessionIdTb4b4b4) Tff7b72?: Tff7b72returnTf0883e@persistAndPublish Tff7b72null
Te6edf3updateSessionAggregatesTb4b4b4(Te6edf3sessionIdTb4b4b4, Te6edf3aggregatesTb4b4b4)
Te6edf3discoveryDaoTb4b4b4.Te6edf3getSessionTb4b4b4(Te6edf3sessionIdTb4b4b4)
Tb4b4b4}
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffpersistAndPublishTb4b4b4(
Te6edf3failureMessageTb4b4b4: Tffa657StringTb4b4b4,
Te6edf3updateTb4b4b4: Te6edf3suspend Tb4b4b4(Tb4b4b4) Tff7b72-Tff7b72> Te6edf3DiscoverySessionEntity?Tb4b4b4,
Tb4b4b4)Tb4b4b4: Tffa657Boolean Tb4b4b4{
Tff7b72val Te6edf3result Tff7b72= Te6edf3safeCatching Tb4b4b4{ Te6edf3updateTb4b4b4(Tb4b4b4) Tb4b4b4}
Tff7b72val Te6edf3failure Tff7b72= Te6edf3resultTb4b4b4.Te6edf3exceptionOrNullTb4b4b4(Tb4b4b4)
Tff7b72if Tb4b4b4(Te6edf3failure Tff7b72!Tff7b72= Tff7b72nullTb4b4b4) Te6edf3LoggerTb4b4b4.Te6edf3eTb4b4b4(Te6edf3failureTb4b4b4) Tb4b4b4{ Ta5d6ff"Ta5d6ffDiscoveryScanEngine: Tffd700$Te6edf3failureMessageTa5d6ff" Tb4b4b4}
Tff7b72val Te6edf3updated Tff7b72= Te6edf3resultTb4b4b4.Te6edf3getOrNullTb4b4b4(Tb4b4b4)
Tff7b72if Tb4b4b4(Te6edf3failure Tff7b72=Tff7b72= Tff7b72null Tff7b72&Tff7b72& Te6edf3updated Tff7b72=Tff7b72= Tff7b72nullTb4b4b4) Tb4b4b4{
Te6edf3LoggerTb4b4b4.Te6edf3e Tb4b4b4{ Ta5d6ff"Ta5d6ffDiscoveryScanEngine: Tffd700$Te6edf3failureMessageTa5d6ff; the session row was not foundTa5d6ff" Tb4b4b4}
Tb4b4b4}
Te6edf3updatedTff7b72?.Te6edf3letTb4b4b4(Te6edf3onSessionUpdatedTb4b4b4)
Tff7b72return Te6edf3updated Tff7b72!Tff7b72= Tff7b72null
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffcalculateSessionAggregatesTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4)Tb4b4b4: Te6edf3SessionAggregates? Tb4b4b4{
Tff7b72if Tb4b4b4(Te6edf3discoveryDaoTb4b4b4.Te6edf3getSessionTb4b4b4(Te6edf3sessionIdTb4b4b4) Tff7b72=Tff7b72= Tff7b72nullTb4b4b4) Tff7b72return Tff7b72null
Tff7b72val Te6edf3presetResults Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3getPresetResultsTb4b4b4(Te6edf3sessionIdTb4b4b4)
Tff7b72val Te6edf3avgChannelUtilization Tff7b72=
Te6edf3presetResults
Tb4b4b4.Te6edf3filter Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3uniqueNodes Tff7b72> T79c0ff0 Tb4b4b4}
Tb4b4b4.Te6edf3map Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3avgChannelUtilization Tb4b4b4}
Tb4b4b4.Te6edf3averageTb4b4b4(Tb4b4b4)
Tb4b4b4.Te6edf3takeIf Tb4b4b4{ Tff7b72!Tffa657itTb4b4b4.Te6edf3isNaNTb4b4b4(Tb4b4b4) Tb4b4b4} Tff7b72?: T79c0ff0.0
Tff7b72return Te6edf3SessionAggregatesTb4b4b4(
Te6edf3totalUniqueNodes Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3getUniqueNodeCountTb4b4b4(Te6edf3sessionIdTb4b4b4)Tb4b4b4,
Te6edf3totalDwellSeconds Tff7b72= Te6edf3presetResultsTb4b4b4.Te6edf3sumOf Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3dwellDurationSeconds Tb4b4b4}Tb4b4b4,
Te6edf3totalMessages Tff7b72= Te6edf3presetResultsTb4b4b4.Te6edf3sumOf Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3messageCount Tb4b4b4}Tb4b4b4,
Te6edf3totalSensorPackets Tff7b72= Te6edf3presetResultsTb4b4b4.Te6edf3sumOf Tb4b4b4{ Tffa657itTb4b4b4.Te6edf3sensorPacketCount Tb4b4b4}Tb4b4b4,
Te6edf3furthestNodeDistance Tff7b72= Te6edf3discoveryDaoTb4b4b4.Te6edf3getMaxDistanceTb4b4b4(Te6edf3sessionIdTb4b4b4) Tff7b72?: T79c0ff0.0Tb4b4b4,
Te6edf3avgChannelUtilization Tff7b72= Te6edf3avgChannelUtilizationTb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tff7b72private Tff7b72suspend Tff7b72fun Td2a8ffupdateSessionAggregatesTb4b4b4(Te6edf3sessionIdTb4b4b4: Tffa657LongTb4b4b4, Te6edf3aggregatesTb4b4b4: Te6edf3SessionAggregatesTb4b4b4) Tb4b4b4{
Te6edf3discoveryDaoTb4b4b4.Te6edf3updateSessionAggregatesTb4b4b4(
Te6edf3sessionId Tff7b72= Te6edf3sessionIdTb4b4b4,
Te6edf3totalUniqueNodes Tff7b72= Te6edf3aggregatesTb4b4b4.Te6edf3totalUniqueNodesTb4b4b4,
Te6edf3totalDwellSeconds Tff7b72= Te6edf3aggregatesTb4b4b4.Te6edf3totalDwellSecondsTb4b4b4,
Te6edf3totalMessages Tff7b72= Te6edf3aggregatesTb4b4b4.Te6edf3totalMessagesTb4b4b4,
Te6edf3totalSensorPackets Tff7b72= Te6edf3aggregatesTb4b4b4.Te6edf3totalSensorPacketsTb4b4b4,
Te6edf3furthestNodeDistance Tff7b72= Te6edf3aggregatesTb4b4b4.Te6edf3furthestNodeDistanceTb4b4b4,
Te6edf3avgChannelUtilization Tff7b72= Te6edf3aggregatesTb4b4b4.Te6edf3avgChannelUtilizationTb4b4b4,
Tb4b4b4)
Tb4b4b4}
Tb4b4b4}
Served by rngit 1.5.0 - Generated in 0.12s